package com.shux.kafka;

import java.util.List;

import com.shux.kafka.consumer.IMessageListener;

/**
 * 描述：
 * 
 * <pre>HISTORY
 * ****************************************************************************
 *  ID   DATE           PERSON          REASON
 *  1    2017年9月25日      Simba.Hua         Create
 * ****************************************************************************
 * </pre>
 * @author Simba.Hua
 */
public class StringMessageListener implements IMessageListener<String> {

	@Override
	public void onMessage(List<String> messages) {
		System.out.println("接收到的消息数量为:" + messages.size());
		messages.forEach(s -> {
			System.out.println("-----------------StringMessageListener:" + s);
		});
		
	}

}
